package bsf.baseservice.businessmq.consumer;

import bsf.baseservice.businessmq.model.*;

/**
 消费者信息
 
*/
public class ConsumerInfo
{
	/** 
	 消费者客户端Client相关信息
	 
	*/
	public tb_consumer_client_model ConsumerClientModel;
	/** 
	 消费者信息
	 
	*/
	public tb_consumer_model ConsumerModel;
	/** 
	 消费者当前使用的可用分区信息
	 
	*/
	public java.util.ArrayList<tb_consumer_partition_model> ConsumerPartitionModels;

	/** 
	 消费者相关分区节点信息
	 
	*/
	public java.util.HashMap <Integer,tb_datanode_model> DataNodeModelDic;
	/** 
	 消费者订阅队列信息
	 
	*/
	public tb_mqpath_model MQPathModel;

}